// NEW: Normalize content type to match decoder keys

function normalizeContentType(contentType: string): string {

  const normalized \= contentType.toLowerCase().split(';')[0].trim();

  if (normalized.includes('json')) return 'application/json';

  if (normalized.includes('csv')) return 'text/csv';

  if (normalized \=== 'application/sbx-bytes-ts') return 'application/sbx-bytes-ts';

  if (normalized \=== 'application/sbx-bytes') return 'application/sbx-bytes';

  return normalized;

}

// UPDATED: Use normalized content-type for decoder lookup

export async function decodeMeasurements(

  measurements: any,

  options: { contentType: string; sensors: any[] }

): Promise<any[]> {

  try {

const normalizedContentType \= normalizeContentType(options.contentType); // ADDED

const handler \= decodeHandlers\[normalizedContentType\]; // CHANGED

if (!handler) { // ADDED null check

  throw new Error(\`No decoder found for content-type: ${options.contentType}\`);

}

return handler.decodeMessage(measurements, { sensors: options.sensors });
  } catch (err: any) {

const error \= new Error(err.message);

error.name \= "ModelError";

(error as any).type \= "UnprocessableEntityError";

throw error;
  }
}